 
 	 import { ref } from "vue";
 	  export const socketDataList=ref([]) ;
	  let ws=null;
	  let reconnectTimer = null; // 断线重连定时器
	  	let againTime = 3; // 重连等待时间(单位秒)
		
		
	 
  	   export function connectWebSocket() {
		   
 		  console.log(process.env.ENV_SOCKET_URL+'/'+getApp().globalData.token);
		  ws=null;
				ws = uni.connectSocket({
				    url: process.env.ENV_SOCKET_URL+'/'+getApp().globalData.token, // 替换为你的 WebSocket 服务器 URL
				    success: function (res) {
				        console.log('WebSocket连接已打开！', res);
				    },
				    fail: function (err) {
				        console.error('WebSocket连接打开失败！', err);
						reconnect();
						
				    }
				});
			
	   
	     
	        // 监听 WebSocket 连接打开事件
	        ws.onOpen(function (res) {
	            console.log('WebSocket 已连接', res);
	        });
	     
	        // 监听 WebSocket 消息事件
	        ws.onMessage(function (res) {
			//	console.log("ws.onMessage"+res.data);
				
	  		     let response= JSON.parse(res.data);
 				   
				   let socketData={
					   "message":response.data,
					   "messageType":response.messageType
				   }

 	  			   socketDataList.value.push(socketData);
				   
	        });
	     
	        // 监听 WebSocket 错误事件
	        ws.onError(function (err) {
	            console.error('WebSocket错误：', err);
				reconnect();
				
	        });
	     
	        // 监听 WebSocket 关闭事件
	        ws.onClose(function (res) {
	            console.log('WebSocket 已关闭！', res);
				reconnect();
	        });
	  	   
	  	   
	    }
		
	  // 重新连接
		function  reconnect() {
			        console.log("websocket开始重连");
				    clearTimeout(reconnectTimer);
				    // 如果不是人为关闭的话，进行重连
				      reconnectTimer = setTimeout(() => {
				        connectWebSocket();
				      }, againTime * 1000);
				    
		}		

		
	    export function sendSocket(ms) {
    			      ws.send({
				         data: ms
				       }); 
		}
	  
	  	   
 
 
	      